package com.dx.chat.kafka.constants;

/**
 * 消息topic产量，用于生产者发送时
 *
 * @author wcx
 * @date 2023/6/29
 */
public interface TopicConstants {

    /**
     * 发送消息topic
     */
    String SEND_MESSAGE = "send_message_topic";

    /**
     * 未读消息topic
     */
    String UNREAD_MESSAGE = "unread_message_topic";

    /**
     * 离线消息topic
     */
    String OFFLINE_MESSAGE = "offline_message_topic";


    /**
     * 实时同步库表给客户端
     */
    String DATASOURCE_SYNC = "datasource_sync_topic";
    /**
     * 离线消息推送队列
     */
    String OFFLINE_MESSAGE_PUSH = "offline_message_push_topic";

}
